package com.webcat.service;

import com.webcat.entity.SseResponse;
import reactor.core.publisher.Flux;

public interface ToolService {

    String start();

    /**
     * @param chatId
     * @param message
     * @param toolId
     * @param toolId 1:数据库查询，2:天气查询
     * @param multiConversation
     * @return
     */
    Flux<SseResponse<Object>> streamChat(String chatId, String message, String toolId, Boolean multiConversation);

    String chat(String chatId, String message, String datasetId, String questionType, Boolean multiConversation);
}
